package com.finance.service;

import com.baomidou.mybatisplus.extension.service.IService;
import com.finance.entity.AsyncRequest;

import java.util.List;

public interface AsyncRequestService extends IService<AsyncRequest> {
    
    /**
     * 创建异步请求记录
     */
    void createAsyncRequest(String dataType, String searchDate, String cinemaId, String traceId);
    
    /**
     * 更新异步请求状态
     */
    void updateStatus(Long id, Integer status, String errorMessage);
    
    /**
     * 获取待处理的异步请求
     */
    List<AsyncRequest> getPendingRequests();
    
    /**
     * 增加重试次数
     */
    void incrementRetryCount(Long id);
} 